package com.SparkCore.RDD.Builder

import org.apache.spark.{SparkConf, SparkContext}

/**
 * 从内存中创建RDD  分区
 */
object Spark01_RDD_Memory_Par1 {
  def main(args: Array[String]): Unit = {

    //准备环境
    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("RDD") //setMaster("Local[*]") 表示默认核数
    val sc = new SparkContext(sparkConf)

    //创建RDD
    val rdd = sc.makeRDD(
      List(1, 2, 3, 4, 5, 6, 7),
      2
    )
    //将分区出来数据进行存储位置文件夹
    rdd.saveAsTextFile("output")

    //关闭环境
    sc.stop()
  }
}
